var mysql = require('mysql')
var pool = mysql.createPool({
    connectionLimit: 10,
    host: 'localhost',
    user: "root",
    password: '',
    database:'node'
})
/* 3. 定义一个数据库查询的方法 */
/* 
    @sql 查询的语句
    @values 查询语句中的值
    @callback 查询成功回调函数
*/
function query(sql, value, callback) {
    pool.getConnection(function (err, connection) {
        if (err) throw err;
        connection.query(sql, value, function (err, res, fields) {
            if (err) throw err;
            callback(err, res)   //回调
            connection.release();   //释放链接，但不是断开
        })
    })
}
/* 定义一个异步promise查询请求 */
function queryPromise(sql,value) {
    return new Promise(function (resolve, reject) {
        pool.getConnection(function (err, connection) {
            if (err) throw err;
            connection.query(sql, value, function (err, res, fields) {
                if (err) throw err;
                resolve(res)   //回调
                connection.release();   //释放链接，但不是断开
            })
        })
    })
}

exports.queryPromise=queryPromise
exports.query=query